package com.shiqi.bio.version2;

import java.io.IOException;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.Socket;
import java.util.Scanner;

/**
 * @author shiqi
 * @version 1.0.0
 * @ClassName ClientDemo.java
 * @Description
 * @createTime 2022-05-13
 */
public class ClientDemo {

    public static void main(String[] args) throws IOException {
        System.out.println("==客户端启动==");
        // （1）创建一个Socket的通信管道，请求与服务端的端口连接。
        Socket socket = new Socket("127.0.0.1", 8888);
        OutputStream os = socket.getOutputStream();
        // （3）把字节流改装成自己需要的流进行数据的发送
        PrintStream ps = new PrintStream(os);
        // （4）开始发送消息
        Scanner scanner = new Scanner(System.in);
        while (true) {
            System.out.println("请输入要发送的信息：");
            // 阻塞等待输入
            String msg = scanner.nextLine();
            ps.println(msg); // 发送一行数据
            ps.flush();
        }
    }
}
